package utils

import (
	"bytes"
	"fmt"
	"io"
	"mime/multipart"

	"github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func Upload(h *multipart.FileHeader) string {
	res, _ := h.Open()
	key, _ := io.ReadAll(res)

	//fmt.Println(key)
	// 创建OSSClient实例。
	// yourEndpoint填写Bucket对应的Endpoint，以华东1（杭州）为例，填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
	client, err := oss.New("https://oss-cn-beijing.aliyuncs.com", "LTAI5tEsTpQT7cvgVEUfN7Mq", "kyKhBBiXdUES1QCjZI1B3549NDxfXK")
	if err != nil {
		fmt.Println("Error:", err.Error())
		return ""

	}

	// 填写存储空间名称，例如examplebucket。
	bucket, err := client.Bucket("wm11-10")
	if err != nil {
		fmt.Println("Error:", err.Error())
		return ""

	}

	// 将Byte数组上传至exampledir目录下的exampleobject.txt文件。
	err = bucket.PutObject(h.Filename, bytes.NewReader(key))
	if err != nil {
		fmt.Println("Error:", err.Error())
		return ""
	}
	return "https://wm11-10.oss-cn-beijing.aliyuncs.com/" + h.Filename + "?x-oss-process=image/watermark,text_546L54yb"
}
